package com.cryann.mqttserver.service;

import io.netty.channel.Channel;
import io.netty.handler.codec.mqtt.MqttPublishMessage;
import io.netty.handler.codec.mqtt.MqttSubscribeMessage;
import io.netty.handler.codec.mqtt.MqttUnsubscribeMessage;

/**
 * @author cRyann
 * @date 2018/12/20 0020 10:02
 * @description:
 */
public interface MqttSubject {

    boolean addSubject(Channel ctx, MqttSubscribeMessage msg);

    boolean delSubject(Channel ctx, MqttUnsubscribeMessage msg);

    void publicSub(Object mqttMessage);

    boolean pubAck(Channel ctx, MqttPublishMessage message);

    boolean pubrec(Channel ctx, MqttPublishMessage message);

}
